package cn.doitedu.dfdemo

import java.util.Properties

import cn.doitedu.util.SparkUtil

/**
 * @Date 22.4.10
 * @Created by HANGGE
 * @Description
 */
object C04_MakeDF_MySQL {
  def main(args: Array[String]): Unit = {

    val session = SparkUtil.getSession

    /**
     * 参数一  JDBC 协议的url定位到数据库
     * 参数二   表名
     * 参数三   连接数据库的必要参数
     */
    val  uri = "jdbc:mysql://localhost:3306/doit30"
    val  tableName = "tb_student"
    val props =  new Properties()
    props.setProperty("user" ,"root")
    props.setProperty("password" , "root")

    val df = session.read.jdbc(uri, tableName, props)


    df.printSchema()
    df.show()


  }

}
